package com.suxin.kafka.thread;

import lombok.Data;

import java.util.function.Consumer;

/**
 * @author Tang
 * @classname KafkaConsumerConfig
 * @description [  ]
 * @date 2022/2/15 21:45
 */
@Data
public class KafkaConsumerConfig<E> {

    private String bizName;

    private Integer concurrentSize;

    private Consumer<E> bizService;

}